package org.example.partition;

import org.apache.flink.annotation.Internal;
import org.apache.flink.api.common.functions.Partitioner;
import org.example.bean.WaterSensor;

public class MyPartitioner implements Partitioner<String> {
    @Override
    public int partition(String key, int numPartitions) {
        return (int) (Integer.parseInt(key) % numPartitions);
    }
}
